import pika
# 1.建立RabbitMQ连接；
connection = pika.BlockingConnection(
    pika.ConnectionParameters('127.0.0.1')
)
# 2.声明频道对象；
channel = connection.channel()
# 3.声明Hello world的队列；
queueName = 'Hello World'
channel.queue_declare(queue=queueName)
# 4. 回调函数, 输出接收到的消息；
def callback(ch, method, properties, body):
    print(" 接收到： %r" % body.decode())
# 5. 接收消息队列数据；
channel.basic_consume(
    # 消息队列名称
    queue=queueName,
    # 消费者获取到数据后，自动发送确认信息给消息队列；
    auto_ack=True,
    # 调用回调函数callback；
    on_message_callback=callback
)
print('等待获取数据，按Ctrl+C 退出')
# 启用
channel.start_consuming()
